//package com.example.java.kafka.es9client;
//
//import co.elastic.clients.elasticsearch.core.MgetRequest;
//import co.elastic.clients.elasticsearch.core.MgetResponse;
//import co.elastic.clients.elasticsearch.core.mget.MultiGetOperation;
//
//import java.io.IOException;
//
//public class BatchGetDoc {
//    public static void main(String[] args) {
//        ConnectElasticsearch.connect(client -> {
//            try {
//                // 构建 mget 请求：查询多个 ID
//                MgetRequest mgetRequest = MgetRequest.of(builder -> builder
//                        .index("user") // 默认索引（可被每个操作覆盖）
//                        .docs(
//                                MultiGetOperation.of(op -> op.id("1001")),
//                                MultiGetOperation.of(op -> op.id("1002")),
//                                MultiGetOperation.of(op -> op.id("1003"))
//                        )
//                );
//                // 执行 mget 请求
//                MgetResponse<User> response = client.mget(mgetRequest, User.class);
//                // 遍历所有返回的文档
//                System.out.println("Found " + response.docs().size() + " documents: " + response);
//            } catch (IOException e) {
//                System.err.println("Error during mget: " + e.getMessage());
//                e.printStackTrace();
//            }
//        });
//    }
//}